package com.xueyi.rebar.mq.consumer;

import com.xueyi.common.message.mq.callback.message.CallbackStreamMessage;
import com.xueyi.common.message.mq.stream.AbstractStreamMessageListener;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

@Component
@Slf4j
public class CallbackStreamConsumer extends AbstractStreamMessageListener<CallbackStreamMessage> {
//public class CallbackStreamConsumer  {

    /*@Resource
    private DeptService deptService;*/

    @Override
    public void onMessage(CallbackStreamMessage message) {
        log.info("[rebar onMessage][收到 workflow callback2消息]  伟大的超哥万岁！" + message.getMessage());
        System.out.println("[rebar onMessage][收到 workflow callback2消息]  伟大的超哥万岁！" + message.getMessage());
        //deptService.initLocalCache();
    }

}
